package org.tao.lightningmq.broker.model;

/**
 * @Author lht
 * @date 2025/1/4 - 21:49
 * @description: 请求消费时的请求参数
 */
public class ConsumeQueueConsumeReqModel {

    private String topic;
    private String consumeGroup;
    private Integer queueId;
    private Integer batchSize;

    public ConsumeQueueConsumeReqModel() {
    }

    public ConsumeQueueConsumeReqModel(String topic, String consumeGroup, Integer queueId, Integer batchSize) {
        this.topic = topic;
        this.consumeGroup = consumeGroup;
        this.queueId = queueId;
        this.batchSize = batchSize;
    }

    public String getTopic() {
        return topic;
    }

    public void setTopic(String topic) {
        this.topic = topic;
    }

    public String getConsumeGroup() {
        return consumeGroup;
    }

    public void setConsumeGroup(String consumeGroup) {
        this.consumeGroup = consumeGroup;
    }

    public Integer getQueueId() {
        return queueId;
    }

    public void setQueueId(Integer queueId) {
        this.queueId = queueId;
    }

    public Integer getBatchSize() {
        return batchSize;
    }

    public void setBatchSize(Integer batchSize) {
        this.batchSize = batchSize;
    }

    @Override
    public String toString() {
        return "ConsumeQueueConsumeReqModel{" +
                "topic='" + topic + '\'' +
                ", consumeGroup='" + consumeGroup + '\'' +
                ", queueId=" + queueId +
                ", batchSize=" + batchSize +
                '}';
    }
}
